package com.hong.nsq;

import com.sproutsocial.nsq.Publisher;

/**
 * @author: csh
 * @Date: 2021/6/3 15:17
 * @Description:生产
 */
public class Publish {
    public static void main(String[] args) {
        Publisher publisher = new Publisher("localhost:4150");
        byte[] data = "Hello nsq I'm hong.".getBytes();
        publisher.publishBuffered("nsq_topic", data);

    }
}
